const express = require('express');
const bodyParser = require('body-parser');
const fs = require('fs');
var pool = require('./pool')
var app = express();
app.listen(8080);
app.use(express.static('public'));
// bodyparser 使用querystring  设置
app.use(bodyParser.urlencoded({
    extended:false
}))
// 登录接口
app.post('/login',function(req,res){
    var obj = req.body;
    console.log(obj); 
    // 拿到数据库去找有没有这个账号密码
    // 连接数据库  执行sql语句
    pool.query('select * from userinfo where uname=? and upwd=?',[obj.uname,obj.upwd],function(err,result){
        if(err) throw err;
        console.log(result.length);
        if(result.length>0){
            // res.sendFile(__dirname+'/public/list.html');
            res.sendFile(__dirname+'/public/项目首页.html')

        }else{
            res.send('账号或者密码错误')
        }  
    })
})
// 注册接口
app.post('/regin',function(req,res){
    var obj = req.body;
    console.log(obj); 
    // 拿到数据库去找有没有这个账号密码
    // 连接数据库  执行sql语句
    pool.query('insert into userinfo set ?',[obj],function(err,result){
        if(err) throw err;
        console.log(result.affectedRows);
        if(result.affectedRows>0){
            res.sendFile(__dirname+'/public/login.html')
        }else{
            res.send('注册失败')
        }
        
    })
})

// 查询所有数据
app.get('/list',function(req,res){
    // 连接数据库  执行sql语句
    pool.query('select * from userinfo',function(err,result){
        if(err) throw err;
        console.log(result);  
        res.send(result)
        
    })
})

// http://localhost:8080/del?uid=10
app.get('/del',function(req,res){
    var uid = req.query.uid;
    console.log('要删除的id是'+uid)
  pool.query('delete from userinfo where uid=?',[uid],function(err,result){
      if(err) throw err;
      if(result.affectedRows>0){
          // 删除成功
          res.send('1')
      }else{
          // 删除失败
          res.send('0')
      }
  })  
})
// 查询一条数据
app.get('/search',function(req,res){
    var uid=req.query.uid
    console.log(uid);
    pool.query('select * from userinfo where uid=?',[uid],function(err,result){
        if(err) throw err
        console.log(result);
        res.send(result)
    })
})

// 更新数据
app.get('/update',function(req,res){
    var obj = req.query;
    console.log(obj);
    pool.query('update userinfo set ? where uid=?',[obj,obj.uid],function(err,result){
        if(err) throw err;
        console.log(result);
        if(result.affectedRows>0){
            res.send('1')
        }else{
            res.send('0')
        }
    })
})

